package com.jeffse.light.stream.core.function.advance;

import com.jeffse.light.stream.core.data.context.ProcessContext;
import com.jeffse.light.stream.core.function.base.Function;

import java.io.Serializable;
import java.util.List;

public class CountFunction<T, O>  implements WindowFunction {
    @Override
    public void window(List list, ProcessContext ctx) throws Exception {
        ctx.collect(list.size());
    }
}
